package com.holly.unit.kafka;

import com.holly.unit.kafka.model.Ktopic;

import java.util.Collection;
import java.util.List;

/**
 * 获取kafka元数据
 * @author Administrator
 *
 */
public interface KafkaMetaApi {
	/**
	 * 批量创建topic
	 * @param newTopics 
	 */
	public void createTopic(Collection<Ktopic> newTopics);
	/**
	 * 批量删除topic
	 * @param topics
	 */
	public void deleteTopic(Collection<String> topics);

	/**
	 * 批量获取topic的信息
	 * @param topics
	 * @return 
	 */
	public String getTopicInfo(Collection<String> topics);

	/**
	 * 获取所有topic名称
	 * @return
	 */
	public List<String> getAllTopic();
}
